package cn.ac.iie.bdb_to_mongo.receiver;

import cn.ac.iie.di.datadock.rdata.exchange.client.core.session.receive.REAbstractReceiveMessageHandler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * @auther Fighter Created on 2016/12/2.
 */
public class MessageFailReceiver extends REAbstractReceiveMessageHandler<byte[]> {
    private final Logger LOG = LoggerFactory.getLogger(MessageFailReceiver.class);

    @Override
    public boolean handle(byte[] message) {
        LOG.error("receive message error ! size=" + message.length + " message=" + new String(message));
        return true;
    }
}
